package com.socket.batch.deal;

import com.socket.entity.GpsRecord;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

/**
 * Created by kaddddd on 2017/7/5 0005.
 */
public class BatchDeal extends AbstractDeal{

    public List batchDataList(BlockingQueue queue){
        List<GpsRecord> list = new ArrayList<GpsRecord>();
        queue.drainTo(list/*, eachQuantity*/);
        return list;
    }

}



